# celery启动文件
from celery import Celery

# 创建 celery 实例

celery_app = Celery("meiduo", broker="redis://127.0.0.1:6379/15")  # 15 是指在15号库操作， 总共有 15（ 0-15 ） 个库，不写默认是在 0 号库操作


@celery_app.task()
def send_sms_code(mobile, sms_code, ext):
    # 导入包，写在这里
    import time
    import os
    import sys
    project_path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))  # 工程根目录
    sys.path.insert(0, os.path.join(project_path, 'meiduo'))
    from libs.rl_sms import send_message
    # 发送短信验证码
    time.sleep(5)  # 用来倒计时延迟
    send_message(mobile, sms_code, ext)


@celery_app.task()
def add(x, y):
    import time
    print(x, y)
    time.sleep(5)
    return x + y

# 启动 celery
# 进入 celery_task目录
# celery -A main worker -l info
